package com.java.code.kafka;

/**
 * @author weichuanyuan
 * @e-mail wei.cy@bsoft.com.cn
 * @date 2021/10/19 21:47
 * @package com.java.code.kafka
 * @description
 */

public class MQConsumerInfo {
    private String topic;
    private String tag;
    private Integer concurrency;
    private MQBusinessHandler businessService;

    public MQConsumerInfo() {
    }

    public String getTopic() {
        return this.topic;
    }

    public void setTopic(String topic) {
        this.topic = topic;
    }

    public Integer getConcurrency() {
        return this.concurrency;
    }

    public void setConcurrency(Integer concurrency) {
        this.concurrency = concurrency;
    }

    public String getTag() {
        return this.tag;
    }

    public void setTag(String tag) {
        this.tag = tag;
    }

    public MQBusinessHandler getBusinessService() {
        return this.businessService;
    }

    public void setBusinessService(MQBusinessHandler businessService) {
        this.businessService = businessService;
    }
}
